e2dbfe0486bec03a2625cdb9abe237224cf45066,joker-engine/src/test/java/cs/bilkent/joker/engine/tuplequeue/impl/queue/MultiThreadedTupleQueueTest.java,MultiThreadedTupleQueueTest,shouldPollExactNumberOfTuples,#,204

Before Change


    public void shouldPollExactNumberOfTuples () throws InterruptedException
    {
        queue.disableCapacityCheck();
        final Thread thread = spawnThread( offerTuples( Thread.currentThread(),
                                                        queue,
                                                        asList( newTuple( 1 ), newTuple( 2 ), newTuple( 3 ), newTuple( 4 ) ) ) );
        final List<Tuple> tuples = queue.pollTuples( 2 );
        assertEquals( 2, tuples.size() );

        thread.join();
    }

    @Test

After Change


    @Test
    public void shouldPollExactNumberOfTuples () throws InterruptedException
    {
        queue.offerTuples( asList( newTuple( 1 ), newTuple( 2 ), newTuple( 3 ) ) );

        final List<Tuple> tuples = queue.pollTuples( 2 );
        assertEquals( 2, tuples.size() );